// 数据库连接配置
var mysql = require('mysql');
const conf = {
	host: '139.224.80.73',
	user: 'prophet',
	password: 'wallet',
	database: 'thai',
	charset: 'utf8mb4',
	port: '3306',
	// debug: true,
	connectionLimit: 50
};


// 使用连接池， 提升性能:连接数据库没有响应
const pool = mysql.createPool(conf);

module.exports = {

	// 查询函数
	query: function(sql, options, callback) {
		pool.query(sql, options, function(err, results, fields) {
			if (err) {
				console.error(err);
			}
			//事件驱动回调  
			callback(err, results, fields);

		});

	}
}
